// package reactor;
//
// import java.util.concurrent.Flow;
//
// public class Jdk11FlowDemo {
//     public static void main(String[] args) {
//         Flow.Publisher<String> publisher = subscriber -> {
//             subscriber.onNext("1");
//             subscriber.onNext("2");
//             subscriber.onError(new RuntimeException("error"));
//             // subscriber.onComplete();
//         };
//
//         publisher.subscribe(new Flow.Subscriber<>() {
//             @Override
//             public void onSubscribe(Flow.Subscription subscription) {
//                 subscription.cancel();
//             }
//
//             @Override
//             public void onNext(String item) {
//                 System.out.println(item);
//             }
//
//             @Override
//             public void onError(Throwable throwable) {
//
//             }
//
//             @Override
//             public void onComplete() {
//
//             }
//         });
//     }
// }
